package com.ctsi.canal.starter.handler;

import com.alibaba.otter.canal.protocol.CanalEntry;

/**
 * @author ajh
 * @date 2019/10/24 15:24
 */
public interface RowDataHandler<T> {

    /**
     * 处理行变更
     *
     * @param t            row data
     * @param entryHandler 实体handler
     * @param eventType    事件类型
     * @param <R>          实体类
     * @throws Exception exception
     */
    <R> void handlerRowData(T t, EntryHandler<R> entryHandler, CanalEntry.EventType eventType) throws Exception;
}
